b454af427e0f50c1110d53ddfa7ef450a6f61863,src/main/java/io/hgraphdb/HBaseBulkLoader.java,HBaseBulkLoader,HBaseBulkLoader,#HBaseGraph#,35
Before Change
try {
this.graph = graph;
BufferedMutator.ExceptionListener listener = (e, mutator) -> {
for (int i = 0; i < e.getNumExceptions(); i++) {
LOGGER.warn("Failed to send put: " + e.getRow(i));
}
};
HBaseGraphConfiguration config = graph.configuration();
BufferedMutatorParams edgesMutatorParams =
new BufferedMutatorParams(HBaseGraphUtils.getTableName(config, Constants.EDGES)).listener(listener);
BufferedMutatorParams edgeIndicesMutatorParams =
new BufferedMutatorParams(HBaseGraphUtils.getTableName(config, Constants.EDGE_INDICES)).listener(listener);
BufferedMutatorParams verticesMutatorParams =
new BufferedMutatorParams(HBaseGraphUtils.getTableName(config, Constants.VERTICES)).listener(listener);
BufferedMutatorParams vertexIndicesMutatorParams =
new BufferedMutatorParams(HBaseGraphUtils.getTableName(config, Constants.VERTEX_INDICES)).listener(listener);
edgesMutator = graph.connection().getBufferedMutator(edgesMutatorParams);
edgeIndicesMutator = graph.connection().getBufferedMutator(edgeIndicesMutatorParams);
verticesMutator = graph.connection().getBufferedMutator(verticesMutatorParams);
vertexIndicesMutator = graph.connection().getBufferedMutator(vertexIndicesMutatorParams);
skipWAL = config.getBulkLoaderSkipWAL();
} catch (IOException e) {
After Change
this(new HBaseGraph(config, HBaseGraphUtils.getConnection(config)));
}
public HBaseBulkLoader(HBaseGraph graph) {
this(graph,
getBufferedMutator(graph, Constants.EDGES),
getBufferedMutator(graph, Constants.EDGE_INDICES),
getBufferedMutator(graph, Constants.VERTICES),
getBufferedMutator(graph, Constants.VERTEX_INDICES));
}
private static BufferedMutator getBufferedMutator(HBaseGraph graph, String tableName) {